Example using the pecl/ev loop:#
<?php
class UserHandler implements http\Client\Curl\User
{
private $client;
private $run;
private $ios = [];
private $timeout;
function __construct(http\Client $client) {
$this->client = $client;
}
function init(callable $run) {
$this->run = $run;
}
function timer(int $timeout_ms) {
echo "T";
if (isset($this->timeout)) {
$this->timeout->set($timeout_ms/1000, 0);
$this->timeout->start();
} else {
$this->timeout = new EvTimer($timeout_ms/1000, 0, function() {
if (!call_user_func($this->run, $this->client)) {
if ($this->timeout) {
$this->timeout->stop();
$this->timeout = null;
}
}
});
}
}
function socket($socket, int $action) {
echo "S";
switch ($action) {
case self::POLL_NONE:
break;
case self::POLL_REMOVE:
if (isset($this->ios[(int) $socket])) {
echo "U";
$this->ios[(int) $socket]->stop();
unset($this->ios[(int) $socket]);
}
break;
default:
$ev = 0;
if ($action & self::POLL_IN) {
$ev |= Ev::READ;
}
if ($action & self::POLL_OUT) {
$ev |= Ev::WRITE;
}
if (isset($this->ios[(int) $socket])) {
$this->ios[(int) $socket]->set($socket, $ev);
} else {
$this->ios[(int) $socket] = new EvIo($socket, $ev, function($watcher, $events) use($socket) {
$action = 0;
if ($events & Ev::READ) {
$action |= self::POLL_IN;
}
if ($events & Ev::WRITE) {
$action |= self::POLL_OUT;
}
if (!call_user_func($this->run, $this->client, $socket, $action)) {
if ($this->timeout) {
$this->timeout->stop();
$this->timeout = null;
}
}
});
}
break;
}
}
function once() {
throw new BadMethodCallException("this example uses Ev::run()");
}
function wait(int $timeout_ms = null) {
throw new BadMethodCallException("this example uses Ev::run()");
}
function send() {
throw new BadMethodCallException("this example uses Ev::run()");
}
}
$client = new http\Client;
$client->configure([
"use_eventloop" => new UserHandler($client)
]);
$client->enqueue(new http\Client\Request("GET", "http://example.com/"), function($r) {
var_dump($r->getResponseCode());
});
Ev::run();
?>
Yields:#
TTTTTTTTSTSTSUint(200)